package com.wngbms;

import org.jctools.queues.*;

import java.util.Queue;

public class Demo1 {

    public static void main(String[] args) {

        // 单生产者
        Queue<String> spscArrayQueue = new SpscArrayQueue<>(16);
        Queue<String> spscUnboundedArrayQueue = new SpscUnboundedArrayQueue<>(2);

        Queue<String> spmcArrayQueue = new SpmcArrayQueue<>(16);

        // 多生产者
        Queue<String> mpscArrayQueue = new SpmcArrayQueue<>(16);
        Queue<String> mpscChunkedArrayQueue = new MpscChunkedArrayQueue<>(1024, 1 << 13);
        Queue<String> mpscUnboundedArrayQueue = new MpscUnboundedArrayQueue<>(2);
        Queue<String> mpmcArrayQueue = new MpmcArrayQueue<>(16);
    }
}
